package com.chj.thread.capt06.disruptor;

import java.util.concurrent.Executor;
import java.util.concurrent.Executors;

import com.lmax.disruptor.BlockingWaitStrategy;
import com.lmax.disruptor.dsl.Disruptor;
import com.lmax.disruptor.dsl.ProducerType;

/**
 * 
 * @author Administrator
 *
 */
public class DisruptorTest {
	
	Executor executor = Executors.newCachedThreadPool();
	PCDataFactory factory = new PCDataFactory();
	//
	int bufferSize = 1024;
	Disruptor<PCData> disruptor = new Disruptor<PCData>(factory,bufferSize,
			executor,ProducerType.MULTI,new BlockingWaitStrategy());
//	 = new ThreadFactory();
	//
//	disruptor.handleEventsWithWorkerPool();
	

}
